package main

import (
	"errors"
	"flag"
	"fmt"
	"log"
	"net"
	"net/http"
	"os"
	"os/exec"
	"os/signal"
	"syscall"
	"time"
)

var (
	server   *http.Server
	listener net.Listener
	graceful = flag.Bool("graceful", false, "listen on fd open 3 (internal use only)")
)

func handler(w http.ResponseWriter, r *http.Request) {
	time.Sleep(1 * time.Second)
	fmt.Print("SIGUSR2")

	w.Write([]byte("hello world233333--!!!!"))
}

func main() {
	flag.Parse()

	http.HandleFunc("/hello", handler)
	server = &http.Server{Addr: ":9999"}

	var err error
	if *graceful {
		log.Print("main: Listening to existing file descriptor 3.")
		// cmd.ExtraFiles: If non-nil, entry i becomes file descriptor 3+i.
		// when we put socket FD at the first entry, it will always be 3(0+3)
		// 在linux中，值为0、1、2的fd，分别代表标准输入、标准输出、标准错误输出，因为 0 1 2已经被linux使用了
		// 返回具有给定文件描述符和名称的新文件。如果fd不是有效的文件描述符，则返回值为nil。
		// 3是什么？3其实就是从父进程继承过来的socket fd。虽然子进程可以默认继承父进程绝大多数的文件描述符（除了文件锁之类的），但是golang的标准库os/exec只默认继承stdin stdout stderr这三个。
		// 需要让子进程继承的fd需要在fork之前手动放到ExtraFiles中。由于有了stdin 0 stdout 1 stderr 2，因此其它fd的序号从3开始。
		f := os.NewFile(3, "")
		listener, err = net.FileListener(f) //返回与打开的文件f对应的网络侦听器的副本。

		log.Printf("ln:addr=%v", listener.Addr().String())

		// f.Close() 是干什么的，Close它会有什么影响。这个问题直接的答案是，没有任何影响，只是为了防止资源泄漏。
		f.Close()

		// 在测试发现，在kill -USR2原有的服务结束时，才会响应新打开的服务
	} else {
		log.Print("main: Listening on a new file descriptor.")
		listener, err = net.Listen("tcp", server.Addr)
	}

	if err != nil {
		log.Fatalf("listener error: %v", err)
	}

	go func() {
		// server.Shutdown() stops Serve() immediately, thus server.Serve() should not be in main goroutine
		err = server.Serve(listener)
		log.Printf("server.Serve err: %v\n", err)
	}()
	signalHandler()
	log.Printf("signal end")
}

func reload() error {
	tl, ok := listener.(*net.TCPListener)
	if !ok {
		return errors.New("listener is not tcp listener")
	}

	f, err := tl.File()
	if err != nil {
		return err
	}

	args := []string{"-graceful"}
	cmd := exec.Command(os.Args[0], args...)
	log.Printf("os.args[0]:%s\n", os.Args[0]) //可执行文件名
	cmd.Stdout = os.Stdout
	cmd.Stderr = os.Stderr
	// put socket FD at the first entry
	cmd.ExtraFiles = []*os.File{f}
	return cmd.Start()
}

func signalHandler() {
	ch := make(chan os.Signal, 1)
	signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM)
	for {
		sig := <-ch
		log.Printf("signal: %v", sig)

		//// timeout context for shutdown
		//ctx, _ := context.WithTimeout(context.Background(), 20*time.Second)
		//switch sig {
		//case syscall.SIGINT, syscall.SIGTERM:
		//	// stop
		//	log.Printf("stop")
		//	signal.Stop(ch)
		//	server.Shutdown(ctx)
		//	log.Printf("graceful shutdown")
		//	return
		//case syscall.SIGUSR2:
		//	// reload
		//	log.Printf("reload")
		//	err := reload()
		//	if err != nil {
		//		log.Fatalf("graceful restart error: %v", err)
		//	}
		//	server.Shutdown(ctx)
		//	log.Printf("graceful reload")
		//	return
		//}
	}
}
